package org.raymond.iworks.study.netty.demo.echo;

import io.netty.util.CharsetUtil;

import java.net.DatagramPacket;

/**
 * @author raymond
 * @version V1.0
 * @Description: TODO
 */
public class EchoClient {
    public static void main(String[] args) throws Exception {
        // 初始化本地udp的socket
        LocalUDPSocketProvider.getInstance().initSocket();
        // 启动本地udp监听以接收服务端返回的数据
        LocalUDPDataReciever.getInstance().startup();
        // 循环发送数据给服务端
        while(true){
            // 要发送的数据
            String sendStr = "我是客户端,我的时间戳:"+System.currentTimeMillis();
            byte[] sendBytes = sendStr.getBytes(CharsetUtil.UTF_8);

            // 开始发送
            LocalUDPSocketProvider
                    .getInstance()
                    .getLocalUDPSocket().send(new DatagramPacket(sendBytes, sendBytes.length));
        }
    }
}
